package com.lx.consumer.directreceiver;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.Map;

/**
 * TODO 添加描述
 *
 * @author wangLJ
 * @date 2024/10/15 14:51
 */
//@Component
//@RabbitListener(queues = "TestDirectQueue")//监听的队列名称 TestDirectQueue
public class DirectReceiverTwo3 {

    @RabbitHandler
    public void process(String message ,Message msg, Channel channel) throws IOException {
        System.out.println("FanoutReceiverA消费者收到消息  : " +message.toString()+ msg);

    }

}

